package com.fanxuankai.boot.canal.listener.annotation;

import java.lang.annotation.*;

/**
 * canal 监听器
 *
 * @author fanxuankai
 */
@Inherited
@Target(ElementType.TYPE)
@Retention(RetentionPolicy.RUNTIME)
@Documented
public @interface CanalListener {
    /**
     * 主题
     *
     * @return String
     */
    String topic() default "";

    /**
     * 实体类
     *
     * @return String
     */
    Class<?> entityClass();
}
